package com.authine.cloudpivot.ext.listener;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * @author luoyj
 * @date 2021/2/25.
 * @description
 */
public interface AppMQBinding {
    String APP_INFO = "paas.app.info";
    String APP_INFO_ACK = "paas.app.ack";

    /**
     * 生产者通道绑定
     * 消费成功后，返回应答数据
     * @return
     */
    @Output(APP_INFO_ACK)
    MessageChannel output();


    /**
     * 消费者通道绑定
     * @return
     */
    @Input(APP_INFO)
    MessageChannel input();

    /**
     * 测试生产
     * @return
     */
//    @Output(APP_INFO)
//    MessageChannel outputTest();
}
